package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil
import org.apache.spark.rdd.RDD

/**
 * @Date 22.4.3
 * @Created by HANGGE
 * @Description
 */
object C22_转换算子_Union {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
    // [1 2 3]  [4 5 6]
    val rdd1 = sc.parallelize(List(1, 2, 3, 4, 5, 6), 1)
    // [4 5 6]  [7 8 9]
    val rdd2 = sc.parallelize(List(4, 5, 6 , 7,8,9), 2)
    // 分区数 4  分区数和
    val res = rdd1.union(rdd2)
    res.mapPartitionsWithIndex((p,iters)=>{
      iters.map(x=>x+"----"+p)
    }).foreach(println)
    


  }

}
